//package com.mq;
//
//import com.alibaba.fastjson.JSON;
//
//import com.entity.view.StoreupView;
//import com.service.StoreupService;
//import groovy.util.logging.Slf4j;
//import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
//import org.apache.rocketmq.spring.core.RocketMQListener;
//import org.springframework.stereotype.Component;
//
//import javax.annotation.Resource;
//
//@Component
//@RocketMQMessageListener(topic = "subject-liked", consumerGroup = "subject-liked-consumer")
//@Slf4j
//public class SubjectLikedConsumer implements RocketMQListener<String> {
//
//    @Resource
//    private StoreupService storeupService;
//
//    @Override
//    public void onMessage(String s) {
//        System.out.println("接受收藏mq,消息为" + s);
//        StoreupView storeupView = JSON.parseObject(s, StoreupView.class);
//        storeupService.syncLikedByMsg(storeupView);
//    }
//
//}
